package jp.co.dailyReport;

import java.sql.Connection;
import java.sql.SQLException;

/**
 * DBへのコネクションを管理クラスです。
 */
public class ConnectionFactory implements ConnectionFactoryInterface {

	public static final int MYSQL_PRIMARY = 1;
	private int connectionSource;

	public ConnectionFactory() {
		connectionSource = MYSQL_PRIMARY;
	}

	/**
	 * コネクションを取得したいDBのステータスを
	 * 設定します。
	 * 
	 * @return connectionSource
	 * @throws SQLException
	 */
	public void selectConnectionSource(int connectionSource) {
		this.connectionSource = connectionSource;
	}

	/**
	 * 指定したDBへのコネクションを返します。
	 * 
	 * @return Connection
	 * @throws SQLException
	 */
	public Connection createConnection() throws SQLException {
		Connection conn = null;
		if(this.connectionSource == MYSQL_PRIMARY) {
			conn = DB.getConnectionPrimary();
		} else {
			throw new SQLException("no such a conncection source.");
		}
		return conn;
	}
}
